package com.caine.kafka.consumer;


import org.apache.kafka.clients.consumer.ConsumerRecord;
import org.springframework.kafka.annotation.KafkaListener;
import org.springframework.stereotype.Component;

@Component
public class ConsumerListenser {
    // 消费监听这个地方就应该是上游的配置
    /**
     * 监听
     * @param record
     */
    @KafkaListener(topics = "#{'${kafka.prop.topics}'.split(',')}" ,containerFactory="kafkaListenerConsumerContainerFactory")
    public void listen(ConsumerRecord<String, String> record) {}
}
